package caas

import (
	"context"
	"flow-calc/core"
	"flow-calc/core/log"
	"time"
)

func ConnCaaSDemoHandle(ctx context.Context, conn core.Connector, fn core.Function, flow core.Flow, args interface{}) error {
	log.Logger().Info("-------------> CaasDemoHandle: flowName: %s, cName: %s,fnName: %s,mode:%s ", flow.GetName(), conn.GetName(), fn.GetConfig().FName, fn.GetConfig().FMode)
	// TODO: 待处理
	time.Sleep(3 * time.Second)
	log.Logger().Info("--------------> Call Connector CaasDemoHandle, args form function: %s", args)
	return nil
}
